SpringCloudGateway原理 |
您所在的位置：网站首页 › spring cloud gateway 转发 › SpringCloudGateway原理 |
SpringCloudGateway原理
|
Gateway 总览
SpringCloudGateway核心设计基于Route，每个Route含有多个Predicate和filter，当请求满足Route的所有Predicate时，请求会被当前Route接受，之后Route含有的filter会处理请求，所有的核心逻辑处理都在Filter中。 SpringCloudGateway官网架构图非常清晰描述了gateway的工作原理。
SpringCloudGateway基于webflux实现，后者有一套自己的服务端框架，为了对其进行适配，SpringCloudGateway提供了RoutePredicateHandlerMapping，用于获取处理请求的WebHandler。 RoutePredicateHandlerMapping设计比较简洁，根据请求和配置的Route predicates 查找是否有匹配的Route，如果有匹配的Route则返回FilteringWebHandler，否则返回空请求失败。 HandlerMapping的获取方式如下图：
FilteringWebHandler在应用初始化时构建传入RoutePredicateHandlerMapping，内部不会对FilteringWebHandler有任何的处理，只要有匹配的Route，就返回FilteringWebHandler；无匹配则请求失败。 匹配成功的Route会被放入ServerWebExchange的attribute内，Route会在WebHandler里被取出。 Web HandlerFilteringWebHandler核心逻辑是构建filter chain，处理Request。WebHandler的handle方法如下 @Override public Mono handle(ServerWebExchange exchange) { // 从 ServerWebExchange 里获取 Route Route route = exchange.getRequiredAttribute(GATEWAY_ROUTE_ATTR); // 获取 Route 下定义的 Filter List List gatewayFilters = route.getFilters(); // 合并全局 Filter List List combined = new ArrayList(this.globalFilters); combined.addAll(gatewayFilters); // 根据 order 排序，这步挺重要的，由于 gateway 基于 filter 实现，所以 filter 的顺序至关重要 AnnotationAwareOrderComparator.sort(combined); if (logger.isDebugEnabled()) { logger.debug("Sorted gatewayFilterFactories: " + combined); } // filter 处理请求 return new DefaultGatewayFilterChain(combined).filter(exchange); }画张图简化理解
SpringCloudGateway的请求转发由NettyRoutingFilter实现，后端返回结果由NettyWriteResponseFilter写回ServerWebExchange response内，完成一次gateway转发。 |
【本文地址】
今日新闻 |
推荐新闻 |